package bundle;

import utils.MessageHandler;
import utils.SynchQueue;

public class BundleHandler implements MessageHandler, Runnable{

	SynchQueue incoming = new SynchQueue();
	
	public void handleMessage(String msg) {
		incoming.add(msg);
	}

	void processMessage(String msg) {
		
	}
	
	public void run() {
		while (true) {
			String msg = incoming.get();
			String[] splitMessage = msg.split(":");
			if (splitMessage[2].equalsIgnoreCase("Bundle")) {
				processMessage(msg);
			} else {
				// ApplicationLayer.
			}
		}
	}

}
